#include "app_mqtt.h"
#include "unistd.h"

int recv_callback(char *message)
{
    log_debug("Received message: %s", message);
    return 0;
}

int main(int argc, char const *argv[])
{
    // 初始化MQTT
    app_mqtt_init();
    // 注册回调函数
    app_mqtt_registerRecvCallback(recv_callback);
    // 发送消息
    app_mqtt_send("{\"device_id\":1,\"cur_angle\":3600,\"motor_status\":\"on\"}");
    // 休眠
    sleep(100);
    return 0;
}
